package com.hexiang.config;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

@Configuration
public class KafkaListenerConfiguration {

    private final Logger logger = LoggerFactory.getLogger(KafkaListenerConfiguration.class);

    @KafkaListener(topics = KafkaConsumerConstant.KAFKA_TOPIC_ITOPENER_DEMO)
    public void process(String content) {
        logger.info("kafka received msg : " + content);
    }

}
